fb290831dc49f0aa79ab69a4bde517f7bf6277e1,src/main/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueStore.java,SingleChronicleQueueStore,writeMarshallable,#WireOut#,299

Before Change


        if (lastAcknowledgedIndexReplicated == null)
            lastAcknowledgedIndexReplicated = wire.newLongReference();

        wire.write(MetaDataField.wireType).object(wireType)
                .write(MetaDataField.roll).typedMarshallable(this.roll)
                .write(MetaDataField.indexing).typedMarshallable(this.indexing)
                .write(MetaDataField.lastAcknowledgedIndexReplicated)
                .int64forBinding(-1L, lastAcknowledgedIndexReplicated);
        wire.write(MetaDataField.recovery).typedMarshallable(recovery);
        wire.write(MetaDataField.deltaCheckpointInterval).int32(this.deltaCheckpointInterval);

        // contended
        wire.padToCacheAlign()
            .write(MetaDataField.writePosition).int64forBinding(0L, writePosition);
    }

    @Override

After Change


        if (lastAcknowledgedIndexReplicated == null)
            lastAcknowledgedIndexReplicated = wire.newLongReference();

        wire.write(MetaDataField.wireType).object(wireType)
                .padToCacheAlign().write(MetaDataField.writePosition).int64forBinding(0L, writePosition)
                .write(MetaDataField.roll).typedMarshallable(this.roll)
                .write(MetaDataField.indexing).typedMarshallable(this.indexing)
                .write(MetaDataField.lastAcknowledgedIndexReplicated)
                .int64forBinding(-1L, lastAcknowledgedIndexReplicated);